from odps import ODPS

if __name__ == '__main__':
    o = ODPS('**', '**', 'nb_dw',
             endpoint='**')
    with o.execute_sql('select * from nb_dw.dm_t_gtzyj_m_fdcqxx_1_delta limit 10').open_reader() as reader4:
        for record in reader4:
            print(record[0:])
    print('SUCCESS!')
